package com.jxm.jdk8features;

import lombok.SneakyThrows;
import org.junit.Test;

import java.util.ArrayList;
import java.util.List;

/**
 * @Author: jxm
 * @Description:
 * @Date: 2024-1-3 16:20
 * @Version: 1.0
 */
public class StreamAPITest2 {

    public static void dataList(){
        try {
            Thread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("------------------完成"+Thread.currentThread().getName());
    }

    /**
     * parallelStream : 是Java 8 Stream API中的一种方法，它允许在多个线程上并行执行流操作。这使得我们能够更有效地利用现代多核处理器的能力。
     */
    @Test
    public void test1(){
        List<Integer> list = new ArrayList<>();
        for (int i = 1; i < 10; i++) {
            list.add(i);
        }
        long l = System.currentTimeMillis();
        list.parallelStream().forEach(item -> {
            StreamAPITest2.dataList();
        });
        System.out.println("====:"+(System.currentTimeMillis()-l));
    }

}
